package springboot.activeMQ ;

import javax.annotation.Resource ;
import javax.jms.Destination ;
import javax.jms.Queue ;

import org.springframework.beans.factory.annotation.Qualifier ;
import org.springframework.jms.core.JmsMessagingTemplate ;
import org.springframework.stereotype.Component ;

/**
 * 消息生产者
 * @author 80002165 @date 2017年7月13日 上午9:55:31
 */
@Component
public class MsgProducer_P2P {
    
    @Resource
    JmsMessagingTemplate jmsMessageingTemplate ;
    
    @Resource
    @Qualifier("defaultQueue")
    Queue defalutQueue ;
    
    public void sendMsg(String msg) {
        jmsMessageingTemplate.convertAndSend(this.defalutQueue, msg) ;
    }
    
    /**
     * 发送消息到指定队列
     * @author 80002165 @date 2017年7月13日 下午2:59:59
     * @param destination
     * @param message
     */
    public void sendMsg(Destination destination, String message) {
        jmsMessageingTemplate.convertAndSend(destination, message) ;
    }
}
